package com.qf.springcloud.airsearch.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface SearchConsumerStream {
    @Input("stream-queue")
    SubscribableChannel input();
}
